PutRecordsRequestEntry entry = new PutRecordsRequestEntry(); entry.setPartitionKey(KEY); entry.setData(VALUE.getBytes()); List<PutRecordsRequestEntry> entries = new ArrayList<PutRecordsRequestEntry>(); entries.add(entry); PutRecordsRequest putRecordsRequest = new PutRecordsRequest(); putRecordsRequest.setStreamName(KINESIS-STREAM-NAME); putRecordsRequest.setRecords(entries); PutRecordsResult putRecordsResult = client.putRecords(putRecordsRequest);